package com.dongrj.framework.starter.log.thread;

import com.dongrj.framework.core.utils.ObjectUtils;
import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * @author dongrongjun
 * @date 2020/4/2
 */
@Slf4j
public class ELKRejectedExecutionHandler implements RejectedExecutionHandler {


    @Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        ELKTask cast = ObjectUtils.cast(r, ELKTask.class);

    }
}
